文章目录 Flink系列文章 一、ApacheKafka连接器 3、kafkasourcefunction 4、kafkasink 1）、使用示例 1、Flink1.13版本实现 2、Flink1.17版本实现 3、说明 2）、序列化器 3）、容错 4）、监控 5、kafkaproducer 6、kafka连接器指标 7、启用Kerberos身份验证 8、升级到最近的连接器版本 9、问题排查 1）、数据丢失 2）、UnknownTopicOrPartitionException 3）、ProducerFencedException 本文介绍了kafka的...